﻿namespace LJ.StreamSystem.LazyHare.Transport.Kafka;

public interface IStreamSystemClientFactory
{
    IStreamSystemClient Create(string applicationId, string aggregateSummaryTopic, string[] aggregateTopics);
}
